package com.zhike.function;

import org.apache.flink.api.common.serialization.SerializationSchema;

/**
 * @Author: zhike
 * @CreateTime: 2024/1/23 17:41
 * @Description:
 */
public class MyKafkaSerialization implements SerializationSchema<String> {
    @Override
    public byte[] serialize(String element) {
        return element.replace("null", "").getBytes();

    }
}
